package cn.dev.admin.queue;

import cn.dev.admin.constant.MqConstant;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author LiuRenGang
 * @date 2022/07/07 10:01
 **/
@Configuration
public class MqQueueConfig {

    @Bean(name = MqConstant.QUEUE_TEST_HELLO)
    public Queue synAddressToEsQueue() {
        return new Queue(MqConstant.QUEUE_TEST_HELLO);
    }

    @Bean(name = MqConstant.SYN_CASE_TO_ES_QUEUE)
    public Queue synCaseToEsQueue() {
        return new Queue(MqConstant.SYN_CASE_TO_ES_QUEUE);
    }
}
